package com.atguigu.activemq.Embed;

import org.apache.activemq.broker.BrokerService;

public class EmbedBroker{
    public static void main(String[] args) throws Exception{
        BrokerService brokerService=new BrokerService();
        brokerService.setUseJmx(true);
        brokerService.addConnector("tcp://localhost:61616");
        //这里自己就是消息服务器，所以填本地localhost;
        brokerService.start();
    }
}
